package com.kwum.ttkuaibao;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;

import net.sf.json.JSONArray;
import net.sf.json.JSONObject;

public class MySQLUtils {

    public static void main(String[] args) throws Exception{
        
    	JSONArray array = new JSONArray();
    	JSONObject json = new JSONObject();
    	json.put("name", "热点");
    	json.put("value", "kb_news_hotnews");
    	array.add(json);
    	json = new JSONObject();
    	json.put("name", "萌宠");
    	json.put("value", "kb_news_pet");
    	array.add(json);
    	json = new JSONObject();
    	json.put("name", "电影");
    	json.put("value", "kb_news_movie");
    	array.add(json);
    	json = new JSONObject();
    	json.put("name", "健身");
    	json.put("value", "kb_news_workout");
    	array.add(json);
    	json = new JSONObject();
    	json.put("name", "猎奇");
    	json.put("value", "kb_news_curious");
    	array.add(json);
    	json = new JSONObject();
    	json.put("name", "电视剧");
    	json.put("value", "kb_news_julebu");
    	array.add(json);
    	json = new JSONObject();
    	json.put("name", "娱乐");
    	json.put("value", "kb_news_bagua");
    	array.add(json);
    	json = new JSONObject();
    	json.put("name", "情感");
    	json.put("value", "kb_news_sex");
    	array.add(json);
    	json = new JSONObject();
    	json.put("name", "美女");
    	json.put("value", "kb_news_beauty");
    	array.add(json);
    	json = new JSONObject();
    	json.put("name", "汽车");
    	json.put("value", "kb_news_car");
    	array.add(json);
    	json = new JSONObject();
    	json.put("name", "军事");
    	json.put("value", "kb_news_mil");
    	array.add(json);
    	json = new JSONObject();
    	json.put("name", "财经");
    	json.put("value", "kb_news_finance");
    	array.add(json);
    	json = new JSONObject();
    	json.put("name", "体育");
    	json.put("value", "kb_news_sports");
    	array.add(json);
    	json = new JSONObject();
    	json.put("name", "动漫");
    	json.put("value", "kb_news_erciyuan");
    	array.add(json);
    	json = new JSONObject();
    	json.put("name", "科技");
    	json.put("value", "kb_news_tech");
    	array.add(json);
    	json = new JSONObject();
    	json.put("name", "房产");
    	json.put("value", "kb_news_house");
    	array.add(json);
    	json = new JSONObject();
    	json.put("name", "国际");
    	json.put("value", "kb_news_world");
    	array.add(json);
    	json = new JSONObject();
    	json.put("name", "历史");
    	json.put("value", "kb_news_history");
    	array.add(json);
    	json = new JSONObject();
    	json.put("name", "搞笑");
    	json.put("value", "kb_news_laugh");
    	array.add(json);
    	json = new JSONObject();
    	json.put("name", "健康");
    	json.put("value", "kb_news_jiankang");
    	array.add(json);
    	json = new JSONObject();
    	json.put("name", "电竞");
    	json.put("value", "kb_news_esport");
    	array.add(json);
    	json = new JSONObject();
    	json.put("name", "职场");
    	json.put("value", "kb_news_career");
    	array.add(json);
    	json = new JSONObject();
    	json.put("name", "育儿");
    	json.put("value", "kb_news_baby");
    	array.add(json);
    	json = new JSONObject();
    	json.put("name", "减肥");
    	json.put("value", "kb_news_diet");
    	array.add(json);
    	json = new JSONObject();
    	json.put("name", "创意");
    	json.put("value", "kb_news_idea");
    	array.add(json);
    	json = new JSONObject();
    	json.put("name", "旅游");
    	json.put("value", "kb_news_travel");
    	array.add(json);
    	json = new JSONObject();
    	json.put("name", "家居");
    	json.put("value", "kb_news_furnishing");
    	array.add(json);
    	json = new JSONObject();
    	json.put("name", "美食");
    	json.put("value", "kb_news_cate");
    	array.add(json);
    	json = new JSONObject();
    	json.put("name", "教育");
    	json.put("value", "kb_news_edu");
    	array.add(json);
    	json = new JSONObject();
    	json.put("name", "三农");
    	json.put("value", "kb_news_farmer");
    	array.add(json);
    	json = new JSONObject();
    	json.put("name", "涨知识");
    	json.put("value", "kb_news_science");
    	array.add(json);
    	json = new JSONObject();
    	json.put("name", "星座");
    	json.put("value", "kb_news_astro");
    	array.add(json);
    	json = new JSONObject();
    	json.put("name", "游戏");
    	json.put("value", "kb_news_game");
    	array.add(json);
    	json = new JSONObject();
    	json.put("name", "时尚");
    	json.put("value", "kb_news_chaobao");
    	array.add(json);
    	json = new JSONObject();
    	json.put("name", "养生");
    	json.put("value", "kb_news_health");
    	array.add(json);
    	for(int i = 0; i < array.size(); i++) {
    		insertCategory(array.getJSONObject(i).getString("name"), array.getJSONObject(i).getString("value"), 3);
    	}
    }
    
    /**
     * 获取数据库连接
     * @param databaseName 数据库名
     * @return
     * @throws Exception
     * @author Kwum
     */
    public static Connection getMySQLConnection(String databaseName) throws Exception{
        //声明Connection对象
        Connection con;
        //驱动程序名
        String driver = "com.mysql.jdbc.Driver";
        //URL指向要访问的数据库名mydata
        String url = "jdbc:mysql://localhost:3306/" + databaseName + "?serverTimezone=UTC&useUnicode=true&characterEncoding=utf-8&useSSL=false";
        //MySQL配置时的用户名
        String user = "root";
        //MySQL配置时的密码
        String password = "Kwum123";
        //加载驱动程序
        Class.forName(driver);
        //1.getConnection()方法，连接MySQL数据库！！
        con = DriverManager.getConnection(url,user,password);
        if(!con.isClosed()){
//            System.out.println("The database connection is complete!");
        }
        return con;
    }
    
    /**
     * 插入天天快报数据
     * @param kuaibao 天天快报
     * @throws Exception
     * @author Kwum
     */
    public static void insertKuaiBaoNewList(TianTianKuaiBao kuaibao) throws Exception{
        //获得数据库的连接
        Connection conn = getMySQLConnection("articlespirder");
        
        String sql="insert ignore into kuaibao_new_list (kuaibao_id, title, url, author, publish_time, comment_count, category) "
        		+ "values(?, ?, ?, ?, ?, ?, ?)";
        //预编译sql语句
        PreparedStatement psmt = conn.prepareStatement(sql);
        //先对应SQL语句，给SQL语句传递参数
        psmt.setString(1, kuaibao.getTtkuaibaoId());
        psmt.setString(2, kuaibao.getTitle());
        psmt.setString(3, kuaibao.getUrl());
        psmt.setString(4, kuaibao.getAuthor());
        psmt.setString(5, kuaibao.getPublishTime());
        psmt.setInt(6, kuaibao.getCommentCount());
        psmt.setString(7, kuaibao.getCategory());
        //执行SQL语句
        psmt.execute();
        conn.close();
    }
    
    public static void insertCategory(String name, String value, Integer sourceId) throws Exception{
        //获得数据库的连接
        Connection conn = getMySQLConnection("articlespirder");
        
        String sql="insert ignore into category (name, value, source) "
        		+ "values(?, ?, ?)";
        //预编译sql语句
        PreparedStatement psmt = conn.prepareStatement(sql);
        //先对应SQL语句，给SQL语句传递参数
        psmt.setString(1, name);
        psmt.setString(2, value);
        psmt.setInt(3, sourceId);
        //执行SQL语句
        psmt.execute();
        conn.close();
    }
}
